package com.arelikebrothers.demo.concurrent.algo.pc.disruptor;

import com.arelikebrothers.demo.concurrent.algo.pc.PCData;
import com.lmax.disruptor.WorkHandler;

/**
 * Created by lennon on 05/05/2017.
 */
public class Consumer implements WorkHandler<PCData> {
    @Override
    public void onEvent(PCData data) throws Exception {
        System.out.println(Thread.currentThread().getName()
            + ":Event: --" + data.getData() + "--");
    }
}
